home *** CD-ROM | disk | FTP | other *** search
/ QRZ! Ham Radio 6 / QRZ Ham Radio Callsign Database - Volume 6.iso / pc / files / amiga / rhinosrc.lha / pppfsm.c < prev    next >
Encoding:
C/C++ Source or Header  |  1993-04-30  |  16.6 KB  |  845 lines
  1. /*
  2.  *  PPPFSM.C    -- PPP Finite State Machine
  3.  *
  4.  *    This implementation of PPP is declared to be in the public domain.
  5.  *
  6.  *    Jan 91    Bill_Simpson@um.cc.umich.edu
  7.  *        Computer Systems Consulting Services
  8.  *
  9.  *    Acknowledgements and correction history may be found in PPP.C
  10.  */
  11.  
  12. #include <stdio.h>
  13. #include <ctype.h>
  14. #include "global.h"
  15. #include "mbuf.h"
  16. #include "iface.h"
  17. #include "ppp.h"
  18. #include "pppfsm.h"
  19. #include "ppplcp.h"
  20. #include "trace.h"
  21.  
  22.  
  23. char *fsmStates[] = {
  24.     "Closed",
  25.     "Listen",
  26.     "Req Sent",
  27.     "Ack Rcvd",
  28.     "Ack Sent",
  29.     "Opened",
  30.     "TermSent"
  31. };
  32.  
  33. char *fsmCodes[] = {
  34.     NULLCHAR,
  35.     "Config Req",
  36.     "Config Ack",
  37.     "Config Nak",
  38.     "Config Reject",
  39.     "Termin Req",
  40.     "Termin Ack",
  41.     "Code Reject",
  42.     "Protocol Reject",
  43.     "Echo Request",
  44.     "Echo Reply",
  45.     "Discard Request",
  46. };
  47.  
  48. static int fsm_sendtermreq __ARGS((struct fsm_s *fsm_p));
  49. static int fsm_sendtermack __ARGS((struct fsm_s *fsm_p, byte_t id));
  50.  
  51. static void fsm_timeout __ARGS((void *vp));
  52.  
  53. static void fsm_reset __ARGS((struct fsm_s *fsm_p));
  54. static void fsm_opening __ARGS((struct fsm_s *fsm_p));
  55.  
  56.  
  57. /************************************************************************/
  58. /* Convert header in host form to network form */
  59. struct mbuf *
  60. htoncnf(cnf, bp)
  61. struct config_hdr *cnf;
  62. struct mbuf *bp;
  63. {
  64.     register char *cp;
  65.  
  66.     /* Prepend bytes for LCP/IPCP header */
  67.     bp = pushdown(bp, CONFIG_HDR_LEN);
  68.  
  69.     /* Load header with proper values */
  70.     cp = bp->data;
  71.     *cp++ = cnf->code;
  72.     *cp++ = cnf->id;
  73.     put16(cp, cnf->len);
  74.  
  75.     return bp;
  76. }
  77.  
  78. /* Extract header from incoming packet */
  79. int
  80. ntohcnf(cnf, bpp)
  81. struct config_hdr *cnf;
  82. struct mbuf **bpp;
  83. {
  84.     char cnfb[CONFIG_HDR_LEN];
  85.  
  86.     if ( cnf == NULL )
  87.         return -1;
  88.  
  89.     if ( pullup( bpp, cnfb, CONFIG_HDR_LEN ) < CONFIG_HDR_LEN )
  90.         return -1;
  91.  
  92.         cnf->code = cnfb[0];
  93.         cnf->id = cnfb[1];
  94.     cnf->len = get16(&cnfb[2]);
  95.     return 0;
  96. }
  97.  
  98. /***************************************/
  99. /* Extract configuration option header */
  100. int
  101. ntohopt(opt,bpp)
  102. struct option_hdr *opt;
  103. struct mbuf **bpp;
  104. {
  105.     char optb[OPTION_HDR_LEN];
  106.  
  107.     if ( opt == NULL )
  108.         return -1;
  109.  
  110.     if ( pullup( bpp, optb, OPTION_HDR_LEN ) < OPTION_HDR_LEN )
  111.         return -1;
  112.  
  113.     opt->type = optb[0];
  114.     opt->len = optb[1];
  115.     return 0;
  116. }
  117.  
  118.  
  119. /************************************************************************/
  120. void
  121. fsm_no_action(fsm_p)
  122. struct fsm_s *fsm_p;
  123. {
  124.     PPP_DEBUG_ROUTINES("fsm_no_action()");
  125. }
  126. int
  127. fsm_no_check(fsm_p, hdr, bp)
  128. struct fsm_s *fsm_p;
  129. struct config_hdr *hdr;
  130. struct mbuf *bp;
  131. {
  132.     PPP_DEBUG_ROUTINES("fsm_no_check()");
  133.     return 0;
  134. }
  135.  
  136.  
  137. /************************************************************************/
  138. /* General log routine */
  139. void
  140. fsm_log(fsm_p, comment)
  141. struct fsm_s *fsm_p;
  142. char *comment;
  143. {
  144.     if (PPPtrace > 1)
  145.         trace_log(PPPiface,"%s PPP/%s %-8s; %s",
  146.             fsm_p->ppp_p->iface->name,
  147.             fsm_p->pdc->name,
  148.             fsmStates[fsm_p->state],
  149.             comment);
  150. }
  151.  
  152.  
  153. /************************************************************************/
  154. /* Set a timer in case an expected event does not occur */
  155. void
  156. fsm_timer(fsm_p)
  157. struct fsm_s *fsm_p;
  158. {
  159.     PPP_DEBUG_ROUTINES("fsm_timer()");
  160.  
  161.     start_timer( &(fsm_p->timer) );
  162. }
  163.  
  164.  
  165. /************************************************************************/
  166. /* Send a packet to the remote host */
  167. int
  168. fsm_send(fsm_p,code,id,data)
  169. struct fsm_s *fsm_p;
  170. byte_t code;
  171. byte_t id;
  172. struct mbuf *data;
  173. {
  174.     struct ppp_s *ppp_p = fsm_p->ppp_p;
  175.     struct iface *iface = ppp_p->iface;
  176.     struct config_hdr hdr;
  177.     struct mbuf *bp = NULL; /* OIS */
  178.  
  179.     switch( hdr.code = code ) {
  180.     case CONFIG_REQ:
  181.     case TERM_REQ:
  182.     case ECHO_REQ:
  183.         /* Save ID field for match against replies from remote host */
  184.         fsm_p->lastid = ppp_p->id;
  185.         /* fallthru */
  186.     case PROT_REJ:
  187.     case DISCARD_REQ:
  188.         /* Use a unique ID field value */
  189.         hdr.id = ppp_p->id++;
  190.         break;
  191.  
  192.     case CONFIG_ACK:
  193.     case CONFIG_NAK:
  194.     case CONFIG_REJ:
  195.     case TERM_ACK:
  196.     case CODE_REJ:
  197.     case ECHO_REPLY:
  198.         /* Use ID sent by remote host */
  199.         hdr.id = id;
  200.         break;
  201.  
  202.     default:
  203.         /* we're in trouble */
  204.         trace_log(PPPiface, "%s PPP/%s %-8s;"
  205.             " Send with bogus code: %d",
  206.             iface->name,
  207.             fsm_p->pdc->name,
  208.             fsmStates[fsm_p->state],
  209.             code);
  210.         return -1;
  211.     };
  212.  
  213.     switch( code ) {
  214.     case ECHO_REQ:
  215.     case ECHO_REPLY:
  216.     case DISCARD_REQ:
  217.     {
  218.         struct lcp_s *lcp_p = fsm_p->pdv;
  219.         bp = pushdown(bp, 4);
  220.         put32(bp->data, lcp_p->local.work.magic_number);
  221.         data = bp;
  222.     }
  223.     };
  224.  
  225.     hdr.len = len_p(data) + CONFIG_HDR_LEN;
  226.  
  227.     /* Prepend header to packet data */
  228.     if ((data = htoncnf(&hdr,data)) == NULLBUF)
  229.         return -1;
  230.  
  231.     if (PPPtrace > 1) {
  232.         trace_log(PPPiface, "%s PPP/%s %-8s;"
  233.             " Sending %s, id: %d, len: %d",
  234.             iface->name,
  235.             fsm_p->pdc->name,
  236.             fsmStates[fsm_p->state],
  237.             fsmCodes[code],
  238.             hdr.id,hdr.len);
  239.     }
  240.  
  241.     ppp_p->OutNCP[fsm_p->pdc->fsmi]++;
  242.  
  243.     return( (*iface->output)
  244.         (iface, NULLCHAR, NULLCHAR, fsm_p->pdc->protocol, data) );
  245. }
  246.  
  247.  
  248. /************************************************************************/
  249. /* Send a configuration request */
  250. int
  251. fsm_sendreq(fsm_p)
  252. struct fsm_s *fsm_p;
  253. {
  254.     struct mbuf *bp;
  255.  
  256.     PPP_DEBUG_ROUTINES("fsm_sendreq()");
  257.  
  258.     if ( fsm_p->retry <= 0 )
  259.         return -1;
  260.  
  261.     fsm_p->retry--;
  262.     fsm_timer(fsm_p);
  263.  
  264.     bp = (*fsm_p->pdc->makereq)(fsm_p);
  265.     return( fsm_send(fsm_p, CONFIG_REQ, 0, bp) );
  266. }
  267.  
  268.  
  269. /************************************************************************/
  270. /* Send a termination request */
  271. static int
  272. fsm_sendtermreq(fsm_p)
  273. struct fsm_s *fsm_p;
  274. {
  275.     PPP_DEBUG_ROUTINES("fsm_sendtermreq()");
  276.  
  277.     if ( fsm_p->retry <= 0 )
  278.         return -1;
  279.  
  280.     fsm_p->retry--;
  281.     fsm_timer(fsm_p);
  282.     return( fsm_send(fsm_p, TERM_REQ, 0, NULLBUF) );
  283. }
  284.  
  285.  
  286. /************************************************************************/
  287. /* Send Terminate Ack */
  288. static int
  289. fsm_sendtermack(fsm_p,id)
  290. struct fsm_s *fsm_p;
  291. byte_t id;
  292. {
  293.     PPP_DEBUG_ROUTINES("fsm_sendtermack()");
  294.  
  295.     return( fsm_send(fsm_p, TERM_ACK, id, NULLBUF) );
  296. }
  297.  
  298.  
  299. /************************************************************************/
  300. /* Reset state machine */
  301. static void
  302. fsm_reset(fsm_p)
  303. struct fsm_s *fsm_p;
  304. {
  305.     PPP_DEBUG_ROUTINES("fsm_reset()");
  306.  
  307.     fsm_p->state = (fsm_p->flags & (FSM_ACTIVE | FSM_PASSIVE))
  308.             ? fsmLISTEN : fsmCLOSED;
  309.     fsm_p->retry = fsm_p->try_req;
  310.     fsm_p->retry_nak = fsm_p->try_nak;
  311.  
  312.     (*fsm_p->pdc->reset)(fsm_p);
  313. }
  314.  
  315.  
  316. /************************************************************************/
  317. /* Configuration negotiation complete */
  318. static void
  319. fsm_opening(fsm_p)
  320. struct fsm_s *fsm_p;
  321. {
  322.     fsm_log(fsm_p, "Opened");
  323.  
  324.     stop_timer(&(fsm_p->timer));
  325.  
  326.     (*fsm_p->pdc->opening)(fsm_p);
  327.     fsm_p->state = fsmOPENED;
  328. }
  329.  
  330.  
  331. /************************************************************************/
  332. /*            E V E N T   P R O C E S S I N G            */
  333. /************************************************************************/
  334.  
  335. /* Process incoming packet */
  336. void
  337. fsm_proc(fsm_p,bp)
  338. struct fsm_s *fsm_p;
  339. struct mbuf *bp;
  340. {
  341.     struct config_hdr hdr;
  342.  
  343.     PPPtrace = fsm_p->ppp_p->trace;
  344.     PPPiface = fsm_p->ppp_p->iface;
  345.  
  346.     if ( ntohcnf(&hdr, &bp) == -1 )
  347.         fsm_log( fsm_p, "short configuration packet" );
  348.  
  349.     if (PPPtrace > 1)
  350.         trace_log(PPPiface, "%s PPP/%s %-8s;"
  351.             " Processing %s, id: %d, len: %d",
  352.             fsm_p->ppp_p->iface->name,
  353.             fsm_p->pdc->name,
  354.             fsmStates[fsm_p->state],
  355.             fsmCodes[hdr.code],
  356.             hdr.id,    hdr.len);
  357.  
  358.     hdr.len -= CONFIG_HDR_LEN;        /* Length includes envelope */
  359.     trim_mbuf(&bp, hdr.len);        /* Trim off padding */
  360.  
  361.     switch(hdr.code) {
  362.     case CONFIG_REQ:
  363.         switch(fsm_p->state) {
  364.         case fsmOPENED:        /* Unexpected event? */
  365.             (*fsm_p->pdc->closing)(fsm_p);
  366.             fsm_reset(fsm_p);
  367.             /* fallthru */
  368.         case fsmLISTEN:
  369.             (*fsm_p->pdc->starting)(fsm_p);
  370.             fsm_sendreq(fsm_p);
  371.             /* fallthru */
  372.         case fsmREQ_Sent:
  373.         case fsmACK_Sent:    /* Unexpected event? */
  374.             fsm_p->state =
  375.             ((*fsm_p->pdc->request)(fsm_p, &hdr, bp) == 0)
  376.                 ? fsmACK_Sent : fsmREQ_Sent;
  377.             break;
  378.  
  379.         case fsmACK_Rcvd:
  380.             if ((*fsm_p->pdc->request)(fsm_p, &hdr, bp) == 0) {
  381.                 fsm_opening(fsm_p);
  382.             } else {
  383.                 /* give peer time to respond */
  384.                 fsm_timer(fsm_p);
  385.             }
  386.             break;
  387.  
  388.         case fsmCLOSED:
  389.             /* Don't accept any connections */
  390.             fsm_sendtermack(fsm_p, hdr.id);
  391.             /* fallthru */
  392.         case fsmTERM_Sent:
  393.             /* We are attempting to close connection; */
  394.             /* wait for timeout to resend a Terminate Request */
  395.             free_p(bp);
  396.             break;
  397.         };
  398.         break;
  399.  
  400.     case CONFIG_ACK:
  401.         switch(fsm_p->state) {
  402.         case fsmREQ_Sent:
  403.             if ((*fsm_p->pdc->ack)(fsm_p, &hdr, bp) == 0) {
  404.                 fsm_p->state = fsmACK_Rcvd;
  405.             }
  406.             break;
  407.  
  408.         case fsmACK_Sent:
  409.             if ((*fsm_p->pdc->ack)(fsm_p, &hdr, bp) == 0) {
  410.                 fsm_opening(fsm_p);
  411.             }
  412.             break;
  413.  
  414.         case fsmOPENED:        /* Unexpected event? */
  415.             (*fsm_p->pdc->closing)(fsm_p);
  416.             (*fsm_p->pdc->starting)(fsm_p);
  417.             fsm_reset(fsm_p);
  418.             /* fallthru */
  419.         case fsmACK_Rcvd:    /* Unexpected event? */
  420.             free_p(bp);
  421.             fsm_sendreq(fsm_p);
  422.             fsm_p->state = fsmREQ_Sent;
  423.             break;
  424.  
  425.         case fsmCLOSED:
  426.         case fsmLISTEN:
  427.             /* Out of Sync; kill the remote */
  428.             fsm_sendtermack(fsm_p, hdr.id);
  429.             /* fallthru */
  430.         case fsmTERM_Sent:
  431.             /* We are attempting to close connection; */
  432.             /* wait for timeout to resend a Terminate Request */
  433.             free_p(bp);
  434.             break;
  435.         };
  436.         break;
  437.  
  438.     case CONFIG_NAK:
  439.         switch(fsm_p->state) {
  440.         case fsmREQ_Sent:
  441.         case fsmACK_Sent:
  442.             /* Update our config request to reflect NAKed options */
  443.             if ((*fsm_p->pdc->nak)(fsm_p, &hdr, bp) == 0) {
  444.                 /* Send updated config request */
  445.                 fsm_sendreq(fsm_p);
  446.             }
  447.             break;
  448.  
  449.         case fsmOPENED:        /* Unexpected event? */
  450.             (*fsm_p->pdc->closing)(fsm_p);
  451.             (*fsm_p->pdc->starting)(fsm_p);
  452.             fsm_reset(fsm_p);
  453.             /* fallthru */
  454.         case fsmACK_Rcvd:    /* Unexpected event? */
  455.             free_p(bp);
  456.             fsm_sendreq(fsm_p);
  457.             fsm_p->state = fsmREQ_Sent;
  458.             break;
  459.  
  460.         case fsmCLOSED:
  461.         case fsmLISTEN:
  462.             /* Out of Sync; kill the remote */
  463.             fsm_sendtermack(fsm_p, hdr.id);
  464.             /* fallthru */
  465.         case fsmTERM_Sent:
  466.             /* We are attempting to close connection; */
  467.             /* wait for timeout to resend a Terminate Request */
  468.             free_p(bp);
  469.             break;
  470.         };
  471.         break;
  472.  
  473.     case CONFIG_REJ:
  474.         switch(fsm_p->state) {
  475.         case fsmREQ_Sent:
  476.         case fsmACK_Sent:
  477.             if((*fsm_p->pdc->reject)(fsm_p, &hdr, bp) == 0) {
  478.                 fsm_sendreq(fsm_p);
  479.             }
  480.             break;
  481.  
  482.         case fsmOPENED:        /* Unexpected event? */
  483.             (*fsm_p->pdc->closing)(fsm_p);
  484.             (*fsm_p->pdc->starting)(fsm_p);
  485.             fsm_reset(fsm_p);
  486.             /* fallthru */
  487.         case fsmACK_Rcvd:    /* Unexpected event? */
  488.             free_p(bp);
  489.             fsm_sendreq(fsm_p);
  490.             fsm_p->state = fsmREQ_Sent;
  491.             break;
  492.  
  493.         case fsmCLOSED:
  494.         case fsmLISTEN:
  495.             /* Out of Sync; kill the remote */
  496.             fsm_sendtermack(fsm_p, hdr.id);
  497.             /* fallthru */
  498.         case fsmTERM_Sent:
  499.             /* We are attempting to close connection; */
  500.             /* wait for timeout to resend a Terminate Request */
  501.             free_p(bp);
  502.             break;
  503.         };
  504.         break;
  505.  
  506.     case TERM_REQ:
  507.         fsm_log(fsm_p, "Peer requested Termination");
  508.  
  509.         switch(fsm_p->state) {
  510.         case fsmOPENED:
  511.             fsm_sendtermack(fsm_p, hdr.id);
  512.             (*fsm_p->pdc->closing)(fsm_p);
  513.             (*fsm_p->pdc->stopping)(fsm_p);
  514.             fsm_reset(fsm_p);
  515.             break;
  516.  
  517.         case fsmACK_Rcvd:
  518.         case fsmACK_Sent:
  519.             fsm_p->state = fsmREQ_Sent;
  520.             /* fallthru */
  521.         case fsmREQ_Sent:
  522.         case fsmTERM_Sent:
  523.             /* waiting for timeout */
  524.             /* fallthru */
  525.         case fsmCLOSED:
  526.         case fsmLISTEN:
  527.             /* Unexpected, but make them happy */
  528.             fsm_sendtermack(fsm_p, hdr.id);
  529.             break;
  530.         };
  531.         break;
  532.  
  533.     case TERM_ACK:
  534.         switch(fsm_p->state) {
  535.         case fsmTERM_Sent:
  536.             stop_timer(&(fsm_p->timer));
  537.  
  538.             fsm_log(fsm_p, "Terminated");
  539.             (*fsm_p->pdc->stopping)(fsm_p);
  540.             fsm_reset(fsm_p);
  541.             break;
  542.  
  543.         case fsmOPENED:
  544.             /* Remote host has abruptly closed connection */
  545.             fsm_log(fsm_p, "Terminated unexpectly");
  546.             (*fsm_p->pdc->closing)(fsm_p);
  547.             fsm_reset(fsm_p);
  548.             if ( fsm_sendreq(fsm_p) == 0 ) {
  549.                 fsm_p->state = fsmREQ_Sent;
  550.             }
  551.             break;
  552.  
  553.         case fsmACK_Sent:
  554.         case fsmACK_Rcvd:
  555.             fsm_p->state = fsmREQ_Sent;
  556.             /* fallthru */
  557.         case fsmREQ_Sent:
  558.             /* waiting for timeout */
  559.             /* fallthru */
  560.         case fsmCLOSED:
  561.         case fsmLISTEN:
  562.             /* Unexpected, but no action needed */
  563.             break;
  564.         };
  565.         break;
  566.  
  567.     case CODE_REJ:
  568.         trace_log(PPPiface,"%s PPP/%s Code Reject;"
  569.             " indicates faulty implementation",
  570.             fsm_p->ppp_p->iface->name,
  571.             fsm_p->pdc->name);
  572.         (*fsm_p->pdc->stopping)(fsm_p);
  573.         fsm_reset(fsm_p);
  574.         free_p(bp);
  575.         break;
  576.  
  577.     case PROT_REJ:
  578.         trace_log(PPPiface,"%s PPP/%s Protocol Reject;"
  579.             " please do not use this protocol",
  580.             fsm_p->ppp_p->iface->name,
  581.             fsm_p->pdc->name);
  582.         free_p(bp);
  583.         break;
  584.  
  585.     case ECHO_REQ:
  586.         switch(fsm_p->state) {
  587.         case fsmOPENED:
  588.             fsm_send( fsm_p, ECHO_REPLY, hdr.id, bp );
  589.             break;
  590.  
  591.         case fsmCLOSED:
  592.         case fsmLISTEN:
  593.             /* Out of Sync; kill the remote */
  594.             fsm_sendtermack(fsm_p, hdr.id);
  595.             /* fallthru */
  596.         case fsmREQ_Sent:
  597.         case fsmACK_Rcvd:
  598.         case fsmACK_Sent:
  599.         case fsmTERM_Sent:
  600.             /* ignore */
  601.             free_p(bp);
  602.             break;
  603.         };
  604.         break;
  605.  
  606.     case ECHO_REPLY:
  607.     case DISCARD_REQ:
  608.     case QUALITY_REPORT:
  609.         free_p(bp);
  610.         break;
  611.  
  612.     default:
  613.         trace_log(PPPiface,"%s PPP/%s Unknown packet type: %d;"
  614.             " Sending Code Reject",
  615.             fsm_p->ppp_p->iface->name,
  616.             fsm_p->pdc->name,
  617.             hdr.code);
  618.  
  619.         hdr.len += CONFIG_HDR_LEN;    /* restore length */
  620.         bp = htoncnf( &hdr, bp );    /* put header back on */
  621.         fsm_send( fsm_p, CODE_REJ, hdr.id, bp );
  622.  
  623.         switch(fsm_p->state) {
  624.         case fsmREQ_Sent:
  625.         case fsmACK_Rcvd:
  626.         case fsmACK_Sent:
  627.         case fsmOPENED:
  628.             fsm_p->state = fsmLISTEN;
  629.             break;
  630.  
  631.         case fsmCLOSED:
  632.         case fsmLISTEN:
  633.         case fsmTERM_Sent:
  634.             /* no change */
  635.             break;
  636.         };
  637.         break;
  638.     }
  639. }
  640.  
  641.  
  642. /************************************************************************/
  643. /* Timeout while waiting for reply from remote host */
  644. static void
  645. fsm_timeout(vp)
  646. void *vp;
  647. {
  648.     struct fsm_s *fsm_p = (struct fsm_s *)vp;
  649.  
  650.     PPPtrace = fsm_p->ppp_p->trace;
  651.     PPPiface = fsm_p->ppp_p->iface;
  652.  
  653.     fsm_log( fsm_p, "Timeout" );
  654.  
  655.     switch(fsm_p->state) {
  656.     case fsmREQ_Sent:
  657.     case fsmACK_Rcvd:
  658.     case fsmACK_Sent:
  659.         if (fsm_p->retry > 0) {
  660.             fsm_sendreq(fsm_p);
  661.             fsm_p->state = fsmREQ_Sent;
  662.         } else {
  663.             fsm_log(fsm_p, "Request retry exceeded");
  664.             fsm_reset(fsm_p);
  665.         }
  666.         break;
  667.  
  668.     case fsmTERM_Sent:
  669.         if (fsm_p->retry > 0) {
  670.             fsm_sendtermreq(fsm_p);
  671.         } else {
  672.             fsm_log(fsm_p, "Terminate retry exceeded");
  673.             (*fsm_p->pdc->stopping)(fsm_p);
  674.             fsm_reset(fsm_p);
  675.         }
  676.         break;
  677.  
  678.     case fsmCLOSED:
  679.     case fsmLISTEN:
  680.     case fsmOPENED:
  681.         /* nothing to do */
  682.         break;
  683.     }
  684. }
  685.  
  686.  
  687. /************************************************************************/
  688. /*            I N I T I A L I Z A T I O N            */
  689. /************************************************************************/
  690.  
  691. /* Start FSM (after open event, and physical line up) */
  692. void
  693. fsm_start(fsm_p)
  694. struct fsm_s *fsm_p;
  695. {
  696.     if ( fsm_p->pdv == NULL )
  697.         return;
  698.  
  699.     PPPtrace = fsm_p->ppp_p->trace;
  700.     PPPiface = fsm_p->ppp_p->iface;
  701.  
  702.     fsm_log(fsm_p, "Start");
  703.  
  704.     if ( !(fsm_p->flags & (FSM_ACTIVE | FSM_PASSIVE)) )
  705.         return;
  706.  
  707.     switch ( fsm_p->state ) {
  708.     case fsmCLOSED:
  709.     case fsmLISTEN:
  710.     case fsmTERM_Sent:
  711.         (*fsm_p->pdc->starting)(fsm_p);
  712.         fsm_reset(fsm_p);
  713.  
  714.         if ( fsm_p->flags & FSM_ACTIVE ){
  715.             fsm_sendreq(fsm_p);
  716.             fsm_p->state = fsmREQ_Sent;
  717.         }
  718.         break;
  719.     default:
  720.         /* already started */
  721.         break;
  722.     };
  723. }
  724.  
  725.  
  726. /************************************************************************/
  727. /* Physical Line Down Event */
  728. void
  729. fsm_down(fsm_p)
  730. struct fsm_s *fsm_p;
  731. {
  732.     if ( fsm_p->pdv == NULL )
  733.         return;
  734.  
  735.     PPPtrace = fsm_p->ppp_p->trace;
  736.     PPPiface = fsm_p->ppp_p->iface;
  737.  
  738.     fsm_log(fsm_p, "Down");
  739.  
  740.     switch ( fsm_p->state ) {
  741.     case fsmREQ_Sent:
  742.     case fsmACK_Rcvd:
  743.     case fsmACK_Sent:
  744.         stop_timer(&(fsm_p->timer));
  745.         fsm_reset(fsm_p);
  746.         break;
  747.  
  748.     case fsmOPENED:
  749.         (*fsm_p->pdc->closing)(fsm_p);
  750.         /* fallthru */
  751.     case fsmTERM_Sent:
  752.         fsm_reset(fsm_p);
  753.         break;
  754.  
  755.     case fsmCLOSED:
  756.     case fsmLISTEN:
  757.         /* nothing to do */
  758.         break;
  759.     };
  760. }
  761.  
  762.  
  763. /************************************************************************/
  764. /* Close the connection */
  765. void
  766. fsm_close(fsm_p)
  767. struct fsm_s *fsm_p;
  768. {
  769.     if ( fsm_p->pdv == NULL )
  770.         return;
  771.  
  772.     PPPtrace = fsm_p->ppp_p->trace;
  773.     PPPiface = fsm_p->ppp_p->iface;
  774.  
  775.     fsm_log(fsm_p, "Close");
  776.  
  777.     switch ( fsm_p->state ) {
  778.     case fsmOPENED:
  779.         (*fsm_p->pdc->closing)(fsm_p);
  780.         /* fallthru */
  781.     case fsmACK_Sent:
  782.         fsm_p->retry = fsm_p->try_terminate;
  783.         fsm_sendtermreq(fsm_p);
  784.         fsm_p->state = fsmTERM_Sent;
  785.         break;
  786.  
  787.     case fsmREQ_Sent:
  788.     case fsmACK_Rcvd:
  789.         /* simply wait for REQ timeout to expire */
  790.         fsm_p->retry = 0;
  791.         fsm_p->state = fsmTERM_Sent;
  792.         break;
  793.  
  794.     case fsmLISTEN:
  795.         fsm_p->state = fsmCLOSED;
  796.         break;
  797.  
  798.     case fsmTERM_Sent:
  799.     case fsmCLOSED:
  800.         /* nothing to do */
  801.         break;
  802.     };
  803. }
  804.  
  805.  
  806. /************************************************************************/
  807. /* Initialize the fsm for this protocol
  808.  * Called from protocol _init
  809.  */
  810. void
  811. fsm_init(fsm_p)
  812. struct fsm_s *fsm_p;
  813. {
  814.     struct timer *t = &(fsm_p->timer);
  815.  
  816.     PPP_DEBUG_ROUTINES("fsm_init()");
  817.  
  818.     fsm_p->try_req = fsm_p->pdc->try_req;
  819.     fsm_p->try_nak = fsm_p->pdc->try_nak;
  820.     fsm_p->try_terminate = fsm_p->pdc->try_terminate;
  821.     fsm_reset(fsm_p);
  822.  
  823.     /* Initialize timer */
  824.     t->func = (void (*)())fsm_timeout;
  825.     t->arg = (void *)fsm_p;
  826.     set_timer(t, fsm_p->pdc->timeout);
  827.     fsm_timer(fsm_p);
  828.     stop_timer(t);
  829. }
  830.  
  831.  
  832. void
  833. fsm_free(fsm_p)
  834. struct fsm_s *fsm_p;
  835. {
  836.     if ( fsm_p->pdv != NULL ) {
  837.         (*fsm_p->pdc->free)(fsm_p);
  838.  
  839.         free( fsm_p->pdv );
  840.         fsm_p->pdv = NULL;
  841.     }
  842. }
  843.  
  844.  
  845.